var mysql = require('mysql');

//封装的query方法
let query = function(sql,values){
	var connection = mysql.createConnection({
	  host: '118.25.12.244',   //主机地址，默认localhost
	  user: 'roota',      //数据库账号名
	  password: 'password',   //数据库密码
	  database: 'testdata'     //连接的数据库名
	});
    return new Promise((resolve,reject) => {
		//先连接
        connection.connect(function(err){
            if(err){
                reject(err);
				console.log("数据库连接失败")
            }else{
				//连接成功才查询
				console.log("数据库连接成功")
                connection.query(sql,values,(err,rows) => {
                    if(err){
                        reject(err);
                    }else{
                        resolve(rows);
                    }
					//关闭connection
					connection.end(function(err){
					    if(err){ 
					        return;
					    }
					    console.log('关闭数据库连接');
					});
                })
				
            }
        })
    })
}
module.exports = query;